package com.sun.kafka.properties;

import lombok.Data;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Configuration;

/**
 * kafka生产者者配置参数
 */
@Data
@Configuration
@ConfigurationProperties(prefix = "spring.kafka.producer")
public class KafkaProducerProperty {

    // 集群地址
    private String bootstrapServers;

    // acks机制
    private String acks;

    // 尝试次数
    private Integer retries;

    // 每批次发送消息的数量
    private Integer batchSize;

    // 缓存数据的内存大小
    private Integer bufferMemory;

}
